﻿using BaiTu.QueueEntity;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace BaiTu.IQueueService.Providers
{
    public interface IQueueProvider
    {
        bool IsQueueExists(string queueName);

        void CreateQueue(string queueName);

        void DeleteQueue(string queueName);

        string SendMessage(string queueName, InnerMessageWrapper msg);

        InnerMessageWrapper ReceiveMessage(string queueName, string relatedMsgId = "");
    }
}
